package cn.jinzhu.stream;



import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

//自定义消息通道 1
public interface MyMsggChannel {
    //自定义消息通道
    String INPUT="jinzhu-input"; //输入的就是消费者消息通道
    String OUTPUT="jinzhu-output"; //输出的就是生产者消息通道
    //只是发消息，你要绑定上面那个输出的消息通道
    @Output(OUTPUT)//输出通道，就是生产者
    MessageChannel output();//发消息

    //订阅
    @Input(INPUT)  //输入通道，就是消费者
    SubscribableChannel input();


    /*
    * cloud F版到H版这二个消息通道名称不一样，因为一个叫做生产输出一个叫消费输入，为了接受消息要在配置文件配置属性
    *
    * */
}
